package com.shanks.framework.mq.service;

import com.shanks.framework.mq.enums.MessageRecordStatusEnum;
import com.shanks.framework.mq.model.MessageRecordPO;

/**
 * 消息推送服务类
 */
public interface MessagePushService {

    /**
     * 推送消息到MQ
     * @param messageRecordPO
     * @param oldMessageStatus
     * @return
     */
    boolean pushMessage(MessageRecordPO messageRecordPO, MessageRecordStatusEnum oldMessageStatus);
}
